package cn.iocoder.yudao.module.etl.provider.engine.mysql;

import cn.iocoder.yudao.module.etl.constants.MysqlConstants;
import cn.iocoder.yudao.module.etl.dal.dataobject.DatasetTableField;
import cn.iocoder.yudao.module.etl.dal.dataobject.Datasource;
import cn.iocoder.yudao.module.etl.dal.mysql.DatasetTableFieldMapper;
import cn.iocoder.yudao.module.etl.dto.sqlObj.SQLObj;
import cn.iocoder.yudao.module.etl.provider.query.QueryProvider;
import cn.iocoder.yudao.module.etl.provider.query.QueryProvider2;
import cn.iocoder.yudao.module.etl.request.permission.DatasetRowPermissionsTreeItem;
import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.lang3.ObjectUtils;
import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Service;
import org.stringtemplate.v4.ST;
import org.stringtemplate.v4.STGroup;
import org.stringtemplate.v4.STGroupFile;

import javax.annotation.Resource;
import java.text.MessageFormat;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import java.util.stream.Collectors;

import static cn.iocoder.yudao.module.etl.constants.datasource.SQLConstants.TABLE_ALIAS_PREFIX;


/**
 * @Author gin
 * @Date 2021/5/17 4:11 下午
 */
@Service("engine_mysqlQueryProvider")
public class MysqlQueryProvider extends QueryProvider2 {
    @Resource
    private DatasetTableFieldMapper datasetTableFieldMapper;

    @Override
    public Integer transFieldType(String field) {
        switch (field) {
            case "CHAR":
            case "VARCHAR":
            case "TEXT":
            case "TINYTEXT":
            case "MEDIUMTEXT":
            case "LONGTEXT":
            case "ENUM":
                return 0;// 文本
            case "DATE":
            case "TIME":
            case "YEAR":
            case "DATETIME":
            case "TIMESTAMP":
                return 1;// 时间
            case "INT":
            case "SMALLINT":
            case "MEDIUMINT":
            case "INTEGER":
            case "BIGINT":
                return 2;// 整型
            case "FLOAT":
            case "DOUBLE":
            case "DECIMAL":
                return 3;// 浮点
            case "BIT":
            case "TINYINT":
                return 4;// 布尔
            default:
                return 0;
        }
    }

    @Override
    public String createSQLPreview(String sql, String orderBy) {
        return "SELECT * FROM (" + sqlFix(sql) + ") AS tmp LIMIT 0,1000";
    }

//    @Override
//    public String createQuerySQL(String table, List<DatasetTableField> fields, boolean isGroup, Datasource ds, List<ChartFieldCustomFilterDTO> fieldCustomFilter) {
//        SQLObj tableObj = SQLObj.builder()
//                .tableName((table.startsWith("(") && table.endsWith(")")) ? table : String.format(MysqlConstants.KEYWORD_TABLE, table))
//                .tableAlias(String.format(TABLE_ALIAS_PREFIX, 0))
//                .build();
//        List<SQLObj> xFields = new ArrayList<>();
//        List<SQLObj> xOrders = new ArrayList<>();
//        if (CollectionUtils.isNotEmpty(fields)) {
//            for (int i = 0; i < fields.size(); i++) {
//                DatasetTableField f = fields.get(i);
//                String originField;
//                if (ObjectUtils.isNotEmpty(f.getExtField()) && f.getExtField() == 2) {
//                    // 解析origin name中有关联的字段生成sql表达式
//                    originField = calcFieldRegex(f.getOriginName(), tableObj);
//                } else if (ObjectUtils.isNotEmpty(f.getExtField()) && f.getExtField() == 1) {
//                    originField = String.format(MysqlConstants.KEYWORD_FIX, tableObj.getTableAlias(), f.getDataeaseName());
//                } else {
//                    originField = String.format(MysqlConstants.KEYWORD_FIX, tableObj.getTableAlias(), f.getDataeaseName());
//                }
//                String fieldAlias = String.format(SQLConstants.FIELD_ALIAS_X_PREFIX, i);
//                String fieldName = "";
//                // 处理横轴字段
//                if (f.getDeExtractType() == 1) {
//                    if (f.getDeType() == 2 || f.getDeType() == 3) {
//                        fieldName = String.format(MysqlConstants.UNIX_TIMESTAMP, originField) + "*1000";
//                    } else {
//                        fieldName = originField;
//                    }
//                } else if (f.getDeExtractType() == 0) {
//                    if (f.getDeType() == 2) {
//                        fieldName = String.format(MysqlConstants.CAST, originField, MysqlConstants.DEFAULT_INT_FORMAT);
//                    } else if (f.getDeType() == 3) {
//                        fieldName = String.format(MysqlConstants.CAST, originField, MysqlConstants.DEFAULT_FLOAT_FORMAT);
//                    } else if (f.getDeType() == 1) {
//                        fieldName = String.format(MysqlConstants.STR_TO_DATE, originField, MysqlConstants.DEFAULT_DATE_FORMAT);
//                    } else {
//                        fieldName = originField;
//                    }
//                } else {
//                    if (f.getDeType() == 1) {
//                        String cast = String.format(MysqlConstants.CAST, originField, MysqlConstants.DEFAULT_INT_FORMAT) + "/1000";
//                        fieldName = String.format(MysqlConstants.FROM_UNIXTIME, cast, MysqlConstants.DEFAULT_DATE_FORMAT);
//                    } else if (f.getDeType() == 2) {
//                        fieldName = String.format(MysqlConstants.CAST, originField, MysqlConstants.DEFAULT_INT_FORMAT);
//                    } else if (f.getDeType() == 3) {
//                        fieldName = String.format(MysqlConstants.CAST, originField, MysqlConstants.DEFAULT_FLOAT_FORMAT);
//                    } else {
//                        fieldName = originField;
//                    }
//                }
//                xFields.add(SQLObj.builder()
//                        .fieldName(fieldName)
//                        .fieldAlias(fieldAlias)
//                        .build());
//            }
//        }
//
//        STGroup stg = new STGroupFile(SQLConstants.SQL_TEMPLATE);
//        ST st_sql = stg.getInstanceOf("previewSql");
//        st_sql.add("isGroup", isGroup);
//        if (CollectionUtils.isNotEmpty(xFields)) st_sql.add("groups", xFields);
//        if (ObjectUtils.isNotEmpty(tableObj)) st_sql.add("table", tableObj);
//        String customWheres = transCustomFilterList(tableObj, fieldCustomFilter);
//        List<String> wheres = new ArrayList<>();
//        if (customWheres != null) wheres.add(customWheres);
//        if (CollectionUtils.isNotEmpty(wheres)) st_sql.add("filters", wheres);
//
//        return st_sql.render();
//    }
//
//    @Override
//    public String createQuerySQLAsTmp(String sql, List<DatasetTableField> fields, boolean isGroup, List<ChartFieldCustomFilterDTO> fieldCustomFilter) {
//        return createQuerySQL("(" + sql + ")", fields, isGroup, null, fieldCustomFilter);
//    }
//
//    @Override
//    public String createQueryTableWithPage(String table, List<DatasetTableField> fields, Integer page, Integer pageSize, Integer realSize, boolean isGroup, Datasource ds, List<ChartFieldCustomFilterDTO> fieldCustomFilter) {
//        return createQuerySQL(table, fields, isGroup, null, fieldCustomFilter) + " LIMIT " + (page - 1) * pageSize + "," + realSize;
//    }
//
//    @Override
//    public String createQueryTableWithLimit(String table, List<DatasetTableField> fields, Integer limit, boolean isGroup, Datasource ds, List<ChartFieldCustomFilterDTO> fieldCustomFilter) {
//        return createQuerySQL(table, fields, isGroup, null, fieldCustomFilter) + " LIMIT 0," + limit;
//    }
//
//    @Override
//    public String createQuerySqlWithLimit(String sql, List<DatasetTableField> fields, Integer limit, boolean isGroup, List<ChartFieldCustomFilterDTO> fieldCustomFilter) {
//        return createQuerySQLAsTmp(sql, fields, isGroup, fieldCustomFilter) + " LIMIT 0," + limit;
//    }
//
//    @Override
//    public String createQuerySQLWithPage(String sql, List<DatasetTableField> fields, Integer page, Integer pageSize, Integer realSize, boolean isGroup, List<ChartFieldCustomFilterDTO> fieldCustomFilter) {
//        return createQuerySQLAsTmp(sql, fields, isGroup, fieldCustomFilter) + " LIMIT " + (page - 1) * pageSize + "," + realSize;
//    }
//
//    @Override
//    public String getSQL(String table, List<ChartViewFieldDTO> xAxis, List<ChartViewFieldDTO> yAxis, List<ChartFieldCustomFilterDTO> fieldCustomFilter, List<ChartExtFilterRequest> extFilterRequestList, Datasource ds, ChartViewWithBLOBs view) {
//        SQLObj tableObj = SQLObj.builder()
//                .tableName((table.startsWith("(") && table.endsWith(")")) ? table : String.format(MysqlConstants.KEYWORD_TABLE, table))
//                .tableAlias(String.format(TABLE_ALIAS_PREFIX, 0))
//                .build();
//        List<SQLObj> xFields = new ArrayList<>();
//        List<SQLObj> xOrders = new ArrayList<>();
//        if (CollectionUtils.isNotEmpty(xAxis)) {
//            for (int i = 0; i < xAxis.size(); i++) {
//                ChartViewFieldDTO x = xAxis.get(i);
//                String originField;
//                if (ObjectUtils.isNotEmpty(x.getExtField()) && x.getExtField() == 2) {
//                    // 解析origin name中有关联的字段生成sql表达式
//                    originField = calcFieldRegex(x.getOriginName(), tableObj);
//                } else if (ObjectUtils.isNotEmpty(x.getExtField()) && x.getExtField() == 1) {
//                    originField = String.format(MysqlConstants.KEYWORD_FIX, tableObj.getTableAlias(), x.getDataeaseName());
//                } else {
//                    originField = String.format(MysqlConstants.KEYWORD_FIX, tableObj.getTableAlias(), x.getDataeaseName());
//                }
//                String fieldAlias = String.format(SQLConstants.FIELD_ALIAS_X_PREFIX, i);
//                // 处理横轴字段
//                xFields.add(getXFields(x, originField, fieldAlias));
//
//                // 处理横轴排序
//                if (StringUtils.isNotEmpty(x.getSort()) && Utils.joinSort(x.getSort())) {
//                    xOrders.add(SQLObj.builder()
//                            .orderField(originField)
//                            .orderAlias(fieldAlias)
//                            .orderDirection(x.getSort())
//                            .build());
//                }
//            }
//        }
//        List<SQLObj> yFields = new ArrayList<>();
//        List<String> yWheres = new ArrayList<>();
//        List<SQLObj> yOrders = new ArrayList<>();
//        if (CollectionUtils.isNotEmpty(yAxis)) {
//            for (int i = 0; i < yAxis.size(); i++) {
//                ChartViewFieldDTO y = yAxis.get(i);
//                String originField;
//                if (ObjectUtils.isNotEmpty(y.getExtField()) && y.getExtField() == 2) {
//                    // 解析origin name中有关联的字段生成sql表达式
//                    originField = calcFieldRegex(y.getOriginName(), tableObj);
//                } else if (ObjectUtils.isNotEmpty(y.getExtField()) && y.getExtField() == 1) {
//                    originField = String.format(MysqlConstants.KEYWORD_FIX, tableObj.getTableAlias(), y.getDataeaseName());
//                } else {
//                    originField = String.format(MysqlConstants.KEYWORD_FIX, tableObj.getTableAlias(), y.getDataeaseName());
//                }
//                String fieldAlias = String.format(SQLConstants.FIELD_ALIAS_Y_PREFIX, i);
//                // 处理纵轴字段
//                yFields.add(getYFields(y, originField, fieldAlias));
//                // 处理纵轴过滤
//                yWheres.add(getYWheres(y, originField, fieldAlias));
//                // 处理纵轴排序
//                if (StringUtils.isNotEmpty(y.getSort()) && Utils.joinSort(y.getSort())) {
//                    yOrders.add(SQLObj.builder()
//                            .orderField(originField)
//                            .orderAlias(fieldAlias)
//                            .orderDirection(y.getSort())
//                            .build());
//                }
//            }
//        }
//        // 处理视图中字段过滤
//        String customWheres = transCustomFilterList(tableObj, fieldCustomFilter);
//        // 处理仪表板字段过滤
//        String extWheres = transExtFilterList(tableObj, extFilterRequestList);
//        // 构建sql所有参数
//        List<SQLObj> fields = new ArrayList<>();
//        fields.addAll(xFields);
//        fields.addAll(yFields);
//        List<String> wheres = new ArrayList<>();
//        if (customWheres != null) wheres.add(customWheres);
//        if (extWheres != null) wheres.add(extWheres);
//        List<SQLObj> groups = new ArrayList<>();
//        groups.addAll(xFields);
//        // 外层再次套sql
//        List<SQLObj> orders = new ArrayList<>();
//        orders.addAll(xOrders);
//        orders.addAll(yOrders);
//        List<String> aggWheres = new ArrayList<>();
//        aggWheres.addAll(yWheres.stream().filter(ObjectUtils::isNotEmpty).collect(Collectors.toList()));
//
//        STGroup stg = new STGroupFile(SQLConstants.SQL_TEMPLATE);
//        ST st_sql = stg.getInstanceOf("querySql");
//        if (CollectionUtils.isNotEmpty(xFields)) st_sql.add("groups", xFields);
//        if (CollectionUtils.isNotEmpty(yFields)) st_sql.add("aggregators", yFields);
//        if (CollectionUtils.isNotEmpty(wheres)) st_sql.add("filters", wheres);
//        if (ObjectUtils.isNotEmpty(tableObj)) st_sql.add("table", tableObj);
//        String sql = st_sql.render();
//
//        ST st = stg.getInstanceOf("querySql");
//        SQLObj tableSQL = SQLObj.builder()
//                .tableName(String.format(MysqlConstants.BRACKETS, sql))
//                .tableAlias(String.format(TABLE_ALIAS_PREFIX, 1))
//                .build();
//        if (CollectionUtils.isNotEmpty(aggWheres)) st.add("filters", aggWheres);
//        if (CollectionUtils.isNotEmpty(orders)) st.add("orders", orders);
//        if (ObjectUtils.isNotEmpty(tableSQL)) st.add("table", tableSQL);
//        return sqlLimit(st.render(), view);
//    }
//
//    @Override
//    public String getSQLTableInfo(String table, List<ChartViewFieldDTO> xAxis, List<ChartFieldCustomFilterDTO> fieldCustomFilter, List<ChartExtFilterRequest> extFilterRequestList, Datasource ds, ChartViewWithBLOBs view) {
//        SQLObj tableObj = SQLObj.builder()
//                .tableName((table.startsWith("(") && table.endsWith(")")) ? table : String.format(MysqlConstants.KEYWORD_TABLE, table))
//                .tableAlias(String.format(TABLE_ALIAS_PREFIX, 0))
//                .build();
//        List<SQLObj> xFields = new ArrayList<>();
//        List<SQLObj> xOrders = new ArrayList<>();
//        if (CollectionUtils.isNotEmpty(xAxis)) {
//            for (int i = 0; i < xAxis.size(); i++) {
//                ChartViewFieldDTO x = xAxis.get(i);
//                String originField;
//                if (ObjectUtils.isNotEmpty(x.getExtField()) && x.getExtField() == 2) {
//                    // 解析origin name中有关联的字段生成sql表达式
//                    originField = calcFieldRegex(x.getOriginName(), tableObj);
//                } else if (ObjectUtils.isNotEmpty(x.getExtField()) && x.getExtField() == 1) {
//                    originField = String.format(MysqlConstants.KEYWORD_FIX, tableObj.getTableAlias(), x.getDataeaseName());
//                } else {
//                    if (x.getDeType() == 2 || x.getDeType() == 3) {
//                        originField = String.format(MysqlConstants.CAST, String.format(MysqlConstants.KEYWORD_FIX, tableObj.getTableAlias(), x.getDataeaseName()), MysqlConstants.DEFAULT_FLOAT_FORMAT);
//                    } else {
//                        originField = String.format(MysqlConstants.KEYWORD_FIX, tableObj.getTableAlias(), x.getDataeaseName());
//                    }
//                }
//                String fieldAlias = String.format(SQLConstants.FIELD_ALIAS_X_PREFIX, i);
//                // 处理横轴字段
//                xFields.add(getXFields(x, originField, fieldAlias));
//
//                // 处理横轴排序
//                if (StringUtils.isNotEmpty(x.getSort()) && Utils.joinSort(x.getSort())) {
//                    xOrders.add(SQLObj.builder()
//                            .orderField(originField)
//                            .orderAlias(fieldAlias)
//                            .orderDirection(x.getSort())
//                            .build());
//                }
//            }
//        }
//        // 处理视图中字段过滤
//        String customWheres = transCustomFilterList(tableObj, fieldCustomFilter);
//        // 处理仪表板字段过滤
//        String extWheres = transExtFilterList(tableObj, extFilterRequestList);
//        // 构建sql所有参数
//        List<SQLObj> fields = new ArrayList<>();
//        fields.addAll(xFields);
//        List<String> wheres = new ArrayList<>();
//        if (customWheres != null) wheres.add(customWheres);
//        if (extWheres != null) wheres.add(extWheres);
//        List<SQLObj> groups = new ArrayList<>();
//        groups.addAll(xFields);
//        // 外层再次套sql
//        List<SQLObj> orders = new ArrayList<>();
//        orders.addAll(xOrders);
//
//        STGroup stg = new STGroupFile(SQLConstants.SQL_TEMPLATE);
//        ST st_sql = stg.getInstanceOf("previewSql");
//        st_sql.add("isGroup", false);
//        if (CollectionUtils.isNotEmpty(xFields)) st_sql.add("groups", xFields);
//        if (CollectionUtils.isNotEmpty(wheres)) st_sql.add("filters", wheres);
//        if (ObjectUtils.isNotEmpty(tableObj)) st_sql.add("table", tableObj);
//        String sql = st_sql.render();
//
//        ST st = stg.getInstanceOf("previewSql");
//        st.add("isGroup", false);
//        SQLObj tableSQL = SQLObj.builder()
//                .tableName(String.format(MysqlConstants.BRACKETS, sql))
//                .tableAlias(String.format(TABLE_ALIAS_PREFIX, 1))
//                .build();
//        if (CollectionUtils.isNotEmpty(orders)) st.add("orders", orders);
//        if (ObjectUtils.isNotEmpty(tableSQL)) st.add("table", tableSQL);
//        return sqlLimit(st.render(), view);
//    }
//
//    @Override
//    public String getSQLAsTmpTableInfo(String sql, List<ChartViewFieldDTO> xAxis, List<ChartFieldCustomFilterDTO> fieldCustomFilter, List<ChartExtFilterRequest> extFilterRequestList, Datasource ds, ChartViewWithBLOBs view) {
//        return getSQLTableInfo("(" + sqlFix(sql) + ")", xAxis, fieldCustomFilter, extFilterRequestList, null, view);
//    }
//
//    @Override
//    public String getSQLAsTmp(String sql, List<ChartViewFieldDTO> xAxis, List<ChartViewFieldDTO> yAxis, List<ChartFieldCustomFilterDTO> fieldCustomFilter, List<ChartExtFilterRequest> extFilterRequestList, ChartViewWithBLOBs view) {
//        return getSQL("(" + sql + ")", xAxis, yAxis, fieldCustomFilter, extFilterRequestList, null, view);
//    }
//
//    @Override
//    public String getSQLStack(String table, List<ChartViewFieldDTO> xAxis, List<ChartViewFieldDTO> yAxis, List<ChartFieldCustomFilterDTO> fieldCustomFilter, List<ChartExtFilterRequest> extFilterRequestList, List<ChartViewFieldDTO> extStack, Datasource ds, ChartViewWithBLOBs view) {
//        SQLObj tableObj = SQLObj.builder()
//                .tableName((table.startsWith("(") && table.endsWith(")")) ? table : String.format(MysqlConstants.KEYWORD_TABLE, table))
//                .tableAlias(String.format(TABLE_ALIAS_PREFIX, 0))
//                .build();
//        List<SQLObj> xFields = new ArrayList<>();
//        List<SQLObj> xOrders = new ArrayList<>();
//        List<ChartViewFieldDTO> xList = new ArrayList<>();
//        xList.addAll(xAxis);
//        xList.addAll(extStack);
//        if (CollectionUtils.isNotEmpty(xList)) {
//            for (int i = 0; i < xList.size(); i++) {
//                ChartViewFieldDTO x = xList.get(i);
//                String originField;
//                if (ObjectUtils.isNotEmpty(x.getExtField()) && x.getExtField() == 2) {
//                    // 解析origin name中有关联的字段生成sql表达式
//                    originField = calcFieldRegex(x.getOriginName(), tableObj);
//                } else if (ObjectUtils.isNotEmpty(x.getExtField()) && x.getExtField() == 1) {
//                    originField = String.format(MysqlConstants.KEYWORD_FIX, tableObj.getTableAlias(), x.getDataeaseName());
//                } else {
//                    originField = String.format(MysqlConstants.KEYWORD_FIX, tableObj.getTableAlias(), x.getDataeaseName());
//                }
//                String fieldAlias = String.format(SQLConstants.FIELD_ALIAS_X_PREFIX, i);
//                // 处理横轴字段
//                xFields.add(getXFields(x, originField, fieldAlias));
//
//                // 处理横轴排序
//                if (StringUtils.isNotEmpty(x.getSort()) && Utils.joinSort(x.getSort())) {
//                    xOrders.add(SQLObj.builder()
//                            .orderField(originField)
//                            .orderAlias(fieldAlias)
//                            .orderDirection(x.getSort())
//                            .build());
//                }
//            }
//        }
//        List<SQLObj> yFields = new ArrayList<>();
//        List<String> yWheres = new ArrayList<>();
//        List<SQLObj> yOrders = new ArrayList<>();
//        if (CollectionUtils.isNotEmpty(yAxis)) {
//            for (int i = 0; i < yAxis.size(); i++) {
//                ChartViewFieldDTO y = yAxis.get(i);
//                String originField;
//                if (ObjectUtils.isNotEmpty(y.getExtField()) && y.getExtField() == 2) {
//                    // 解析origin name中有关联的字段生成sql表达式
//                    originField = calcFieldRegex(y.getOriginName(), tableObj);
//                } else if (ObjectUtils.isNotEmpty(y.getExtField()) && y.getExtField() == 1) {
//                    originField = String.format(MysqlConstants.KEYWORD_FIX, tableObj.getTableAlias(), y.getDataeaseName());
//                } else {
//                    originField = String.format(MysqlConstants.KEYWORD_FIX, tableObj.getTableAlias(), y.getDataeaseName());
//                }
//                String fieldAlias = String.format(SQLConstants.FIELD_ALIAS_Y_PREFIX, i);
//                // 处理纵轴字段
//                yFields.add(getYFields(y, originField, fieldAlias));
//                // 处理纵轴过滤
//                yWheres.add(getYWheres(y, originField, fieldAlias));
//                // 处理纵轴排序
//                if (StringUtils.isNotEmpty(y.getSort()) && Utils.joinSort(y.getSort())) {
//                    yOrders.add(SQLObj.builder()
//                            .orderField(originField)
//                            .orderAlias(fieldAlias)
//                            .orderDirection(y.getSort())
//                            .build());
//                }
//            }
//        }
//        // 处理视图中字段过滤
//        String customWheres = transCustomFilterList(tableObj, fieldCustomFilter);
//        // 处理仪表板字段过滤
//        String extWheres = transExtFilterList(tableObj, extFilterRequestList);
//        // 构建sql所有参数
//        List<SQLObj> fields = new ArrayList<>();
//        fields.addAll(xFields);
//        fields.addAll(yFields);
//        List<String> wheres = new ArrayList<>();
//        if (customWheres != null) wheres.add(customWheres);
//        if (extWheres != null) wheres.add(extWheres);
//        List<SQLObj> groups = new ArrayList<>();
//        groups.addAll(xFields);
//        // 外层再次套sql
//        List<SQLObj> orders = new ArrayList<>();
//        orders.addAll(xOrders);
//        orders.addAll(yOrders);
//        List<String> aggWheres = new ArrayList<>();
//        aggWheres.addAll(yWheres.stream().filter(ObjectUtils::isNotEmpty).collect(Collectors.toList()));
//
//        STGroup stg = new STGroupFile(SQLConstants.SQL_TEMPLATE);
//        ST st_sql = stg.getInstanceOf("querySql");
//        if (CollectionUtils.isNotEmpty(xFields)) st_sql.add("groups", xFields);
//        if (CollectionUtils.isNotEmpty(yFields)) st_sql.add("aggregators", yFields);
//        if (CollectionUtils.isNotEmpty(wheres)) st_sql.add("filters", wheres);
//        if (ObjectUtils.isNotEmpty(tableObj)) st_sql.add("table", tableObj);
//        String sql = st_sql.render();
//
//        ST st = stg.getInstanceOf("querySql");
//        SQLObj tableSQL = SQLObj.builder()
//                .tableName(String.format(MysqlConstants.BRACKETS, sql))
//                .tableAlias(String.format(TABLE_ALIAS_PREFIX, 1))
//                .build();
//        if (CollectionUtils.isNotEmpty(aggWheres)) st.add("filters", aggWheres);
//        if (CollectionUtils.isNotEmpty(orders)) st.add("orders", orders);
//        if (ObjectUtils.isNotEmpty(tableSQL)) st.add("table", tableSQL);
//        return sqlLimit(st.render(), view);
//    }
//
//    @Override
//    public String getSQLAsTmpStack(String table, List<ChartViewFieldDTO> xAxis, List<ChartViewFieldDTO> yAxis, List<ChartFieldCustomFilterDTO> fieldCustomFilter, List<ChartExtFilterRequest> extFilterRequestList, List<ChartViewFieldDTO> extStack, ChartViewWithBLOBs view) {
//        return getSQLStack("(" + table + ")", xAxis, yAxis, fieldCustomFilter, extFilterRequestList, extStack, null, view);
//    }
//
//    @Override
//    public String getSQLScatter(String table, List<ChartViewFieldDTO> xAxis, List<ChartViewFieldDTO> yAxis, List<ChartFieldCustomFilterDTO> fieldCustomFilter, List<ChartExtFilterRequest> extFilterRequestList, List<ChartViewFieldDTO> extBubble, Datasource ds, ChartViewWithBLOBs view) {
//        SQLObj tableObj = SQLObj.builder()
//                .tableName((table.startsWith("(") && table.endsWith(")")) ? table : String.format(MysqlConstants.KEYWORD_TABLE, table))
//                .tableAlias(String.format(TABLE_ALIAS_PREFIX, 0))
//                .build();
//        List<SQLObj> xFields = new ArrayList<>();
//        List<SQLObj> xOrders = new ArrayList<>();
//        if (CollectionUtils.isNotEmpty(xAxis)) {
//            for (int i = 0; i < xAxis.size(); i++) {
//                ChartViewFieldDTO x = xAxis.get(i);
//                String originField;
//                if (ObjectUtils.isNotEmpty(x.getExtField()) && x.getExtField() == 2) {
//                    // 解析origin name中有关联的字段生成sql表达式
//                    originField = calcFieldRegex(x.getOriginName(), tableObj);
//                } else if (ObjectUtils.isNotEmpty(x.getExtField()) && x.getExtField() == 1) {
//                    originField = String.format(MysqlConstants.KEYWORD_FIX, tableObj.getTableAlias(), x.getDataeaseName());
//                } else {
//                    originField = String.format(MysqlConstants.KEYWORD_FIX, tableObj.getTableAlias(), x.getDataeaseName());
//                }
//                String fieldAlias = String.format(SQLConstants.FIELD_ALIAS_X_PREFIX, i);
//                // 处理横轴字段
//                xFields.add(getXFields(x, originField, fieldAlias));
//
//                // 处理横轴排序
//                if (StringUtils.isNotEmpty(x.getSort()) && Utils.joinSort(x.getSort())) {
//                    xOrders.add(SQLObj.builder()
//                            .orderField(originField)
//                            .orderAlias(fieldAlias)
//                            .orderDirection(x.getSort())
//                            .build());
//                }
//            }
//        }
//        List<SQLObj> yFields = new ArrayList<>();
//        List<String> yWheres = new ArrayList<>();
//        List<SQLObj> yOrders = new ArrayList<>();
//        List<ChartViewFieldDTO> yList = new ArrayList<>();
//        yList.addAll(yAxis);
//        yList.addAll(extBubble);
//        if (CollectionUtils.isNotEmpty(yList)) {
//            for (int i = 0; i < yList.size(); i++) {
//                ChartViewFieldDTO y = yList.get(i);
//                String originField;
//                if (ObjectUtils.isNotEmpty(y.getExtField()) && y.getExtField() == 2) {
//                    // 解析origin name中有关联的字段生成sql表达式
//                    originField = calcFieldRegex(y.getOriginName(), tableObj);
//                } else if (ObjectUtils.isNotEmpty(y.getExtField()) && y.getExtField() == 1) {
//                    originField = String.format(MysqlConstants.KEYWORD_FIX, tableObj.getTableAlias(), y.getDataeaseName());
//                } else {
//                    originField = String.format(MysqlConstants.KEYWORD_FIX, tableObj.getTableAlias(), y.getDataeaseName());
//                }
//                String fieldAlias = String.format(SQLConstants.FIELD_ALIAS_Y_PREFIX, i);
//                // 处理纵轴字段
//                yFields.add(getYFields(y, originField, fieldAlias));
//                // 处理纵轴过滤
//                yWheres.add(getYWheres(y, originField, fieldAlias));
//                // 处理纵轴排序
//                if (StringUtils.isNotEmpty(y.getSort()) && Utils.joinSort(y.getSort())) {
//                    yOrders.add(SQLObj.builder()
//                            .orderField(originField)
//                            .orderAlias(fieldAlias)
//                            .orderDirection(y.getSort())
//                            .build());
//                }
//            }
//        }
//        // 处理视图中字段过滤
//        String customWheres = transCustomFilterList(tableObj, fieldCustomFilter);
//        // 处理仪表板字段过滤
//        String extWheres = transExtFilterList(tableObj, extFilterRequestList);
//        // 构建sql所有参数
//        List<SQLObj> fields = new ArrayList<>();
//        fields.addAll(xFields);
//        fields.addAll(yFields);
//        List<String> wheres = new ArrayList<>();
//        if (customWheres != null) wheres.add(customWheres);
//        if (extWheres != null) wheres.add(extWheres);
//        List<SQLObj> groups = new ArrayList<>();
//        groups.addAll(xFields);
//        // 外层再次套sql
//        List<SQLObj> orders = new ArrayList<>();
//        orders.addAll(xOrders);
//        orders.addAll(yOrders);
//        List<String> aggWheres = new ArrayList<>();
//        aggWheres.addAll(yWheres.stream().filter(ObjectUtils::isNotEmpty).collect(Collectors.toList()));
//
//        STGroup stg = new STGroupFile(SQLConstants.SQL_TEMPLATE);
//        ST st_sql = stg.getInstanceOf("querySql");
//        if (CollectionUtils.isNotEmpty(xFields)) st_sql.add("groups", xFields);
//        if (CollectionUtils.isNotEmpty(yFields)) st_sql.add("aggregators", yFields);
//        if (CollectionUtils.isNotEmpty(wheres)) st_sql.add("filters", wheres);
//        if (ObjectUtils.isNotEmpty(tableObj)) st_sql.add("table", tableObj);
//        String sql = st_sql.render();
//
//        ST st = stg.getInstanceOf("querySql");
//        SQLObj tableSQL = SQLObj.builder()
//                .tableName(String.format(MysqlConstants.BRACKETS, sql))
//                .tableAlias(String.format(TABLE_ALIAS_PREFIX, 1))
//                .build();
//        if (CollectionUtils.isNotEmpty(aggWheres)) st.add("filters", aggWheres);
//        if (CollectionUtils.isNotEmpty(orders)) st.add("orders", orders);
//        if (ObjectUtils.isNotEmpty(tableSQL)) st.add("table", tableSQL);
//        return sqlLimit(st.render(), view);
//    }
//
//    @Override
//    public String getSQLAsTmpScatter(String table, List<ChartViewFieldDTO> xAxis, List<ChartViewFieldDTO> yAxis, List<ChartFieldCustomFilterDTO> fieldCustomFilter, List<ChartExtFilterRequest> extFilterRequestList, List<ChartViewFieldDTO> extBubble, ChartViewWithBLOBs view) {
//        return getSQLScatter("(" + table + ")", xAxis, yAxis, fieldCustomFilter, extFilterRequestList, extBubble, null, view);
//    }

    @Override
    public String searchTable(String table) {
        return "SELECT table_name FROM information_schema.TABLES WHERE table_name ='" + table + "'";
    }

//    @Override
//    public String getSQLSummary(String table, List<ChartViewFieldDTO> yAxis, List<ChartFieldCustomFilterDTO> fieldCustomFilter, List<ChartExtFilterRequest> extFilterRequestList, ChartViewWithBLOBs view, Datasource ds) {
//        // 字段汇总 排序等
//        SQLObj tableObj = SQLObj.builder()
//                .tableName((table.startsWith("(") && table.endsWith(")")) ? table : String.format(MysqlConstants.KEYWORD_TABLE, table))
//                .tableAlias(String.format(TABLE_ALIAS_PREFIX, 0))
//                .build();
//        List<SQLObj> yFields = new ArrayList<>();
//        List<String> yWheres = new ArrayList<>();
//        List<SQLObj> yOrders = new ArrayList<>();
//        if (CollectionUtils.isNotEmpty(yAxis)) {
//            for (int i = 0; i < yAxis.size(); i++) {
//                ChartViewFieldDTO y = yAxis.get(i);
//                String originField;
//                if (ObjectUtils.isNotEmpty(y.getExtField()) && y.getExtField() == 2) {
//                    // 解析origin name中有关联的字段生成sql表达式
//                    originField = calcFieldRegex(y.getOriginName(), tableObj);
//                } else if (ObjectUtils.isNotEmpty(y.getExtField()) && y.getExtField() == 1) {
//                    originField = String.format(MysqlConstants.KEYWORD_FIX, tableObj.getTableAlias(), y.getDataeaseName());
//                } else {
//                    originField = String.format(MysqlConstants.KEYWORD_FIX, tableObj.getTableAlias(), y.getDataeaseName());
//                }
//                String fieldAlias = String.format(SQLConstants.FIELD_ALIAS_Y_PREFIX, i);
//                // 处理纵轴字段
//                yFields.add(getYFields(y, originField, fieldAlias));
//                // 处理纵轴过滤
//                yWheres.add(getYWheres(y, originField, fieldAlias));
//                // 处理纵轴排序
//                if (StringUtils.isNotEmpty(y.getSort()) && Utils.joinSort(y.getSort())) {
//                    yOrders.add(SQLObj.builder()
//                            .orderField(originField)
//                            .orderAlias(fieldAlias)
//                            .orderDirection(y.getSort())
//                            .build());
//                }
//            }
//        }
//        // 处理视图中字段过滤
//        String customWheres = transCustomFilterList(tableObj, fieldCustomFilter);
//        // 处理仪表板字段过滤
//        String extWheres = transExtFilterList(tableObj, extFilterRequestList);
//        // 构建sql所有参数
//        List<SQLObj> fields = new ArrayList<>();
//        fields.addAll(yFields);
//        List<String> wheres = new ArrayList<>();
//        if (customWheres != null) wheres.add(customWheres);
//        if (extWheres != null) wheres.add(extWheres);
//        List<SQLObj> groups = new ArrayList<>();
//        // 外层再次套sql
//        List<SQLObj> orders = new ArrayList<>();
//        orders.addAll(yOrders);
//        List<String> aggWheres = new ArrayList<>();
//        aggWheres.addAll(yWheres.stream().filter(ObjectUtils::isNotEmpty).collect(Collectors.toList()));
//
//        STGroup stg = new STGroupFile(SQLConstants.SQL_TEMPLATE);
//        ST st_sql = stg.getInstanceOf("querySql");
//        if (CollectionUtils.isNotEmpty(yFields)) st_sql.add("aggregators", yFields);
//        if (CollectionUtils.isNotEmpty(wheres)) st_sql.add("filters", wheres);
//        if (ObjectUtils.isNotEmpty(tableObj)) st_sql.add("table", tableObj);
//        String sql = st_sql.render();
//
//        ST st = stg.getInstanceOf("querySql");
//        SQLObj tableSQL = SQLObj.builder()
//                .tableName(String.format(MysqlConstants.BRACKETS, sql))
//                .tableAlias(String.format(TABLE_ALIAS_PREFIX, 1))
//                .build();
//        if (CollectionUtils.isNotEmpty(aggWheres)) st.add("filters", aggWheres);
//        if (CollectionUtils.isNotEmpty(orders)) st.add("orders", orders);
//        if (ObjectUtils.isNotEmpty(tableSQL)) st.add("table", tableSQL);
//        return sqlLimit(st.render(), view);
//    }
//
//    @Override
//    public String getSQLSummaryAsTmp(String sql, List<ChartViewFieldDTO> yAxis, List<ChartFieldCustomFilterDTO> fieldCustomFilter, List<ChartExtFilterRequest> extFilterRequestList, ChartViewWithBLOBs view) {
//        return getSQLSummary("(" + sql + ")", yAxis, fieldCustomFilter, extFilterRequestList, view, null);
//    }

    @Override
    public String wrapSql(String sql) {
        sql = sql.trim();
        if (sql.lastIndexOf(";") == (sql.length() - 1)) {
            sql = sql.substring(0, sql.length() - 1);
        }
        String tmpSql = "SELECT * FROM (" + sql + ") AS tmp " + " LIMIT 0";
        return tmpSql;
    }

    @Override
    public String createRawQuerySQL(String table, List<DatasetTableField> fields, Datasource ds) {
        String[] array = fields.stream().map(f -> {
            StringBuilder stringBuilder = new StringBuilder();
            stringBuilder.append("`").append(f.getDataeaseName()).append("` AS ").append(f.getDataeaseName());
            return stringBuilder.toString();
        }).toArray(String[]::new);
        return MessageFormat.format("SELECT {0} FROM {1} ORDER BY null", StringUtils.join(array, ","), table);
    }

    @Override
    public String createRawQuerySQLAsTmp(String sql, List<DatasetTableField> fields) {
        return createRawQuerySQL(" (" + sqlFix(sql) + ") AS tmp ", fields, null);
    }

    @Override
    public String transTreeItem(SQLObj tableObj, DatasetRowPermissionsTreeItem item) {
        return null;
    }

    @Override
    public String convertTableToSql(String tableName, Datasource ds) {
        return createSQLPreview("SELECT * FROM " + String.format(MysqlConstants.KEYWORD_TABLE, tableName), null);
    }

    private String sqlFix(String sql) {
        if (sql.lastIndexOf(";") == (sql.length() - 1)) {
            sql = sql.substring(0, sql.length() - 1);
        }
        return sql;
    }

    public String transMysqlFilterTerm(String term) {
        switch (term) {
            case "eq":
                return " = ";
            case "not_eq":
                return " <> ";
            case "lt":
                return " < ";
            case "le":
                return " <= ";
            case "gt":
                return " > ";
            case "ge":
                return " >= ";
            case "in":
                return " IN ";
            case "not in":
                return " NOT IN ";
            case "like":
                return " LIKE ";
            case "not like":
                return " NOT LIKE ";
            case "null":
                return " IS NULL ";
            case "not_null":
                return " IS NOT NULL ";
            case "empty":
                return " = ";
            case "not_empty":
                return " <> ";
            case "between":
                return " BETWEEN ";
            default:
                return "";
        }
    }

//    public String transCustomFilterList(SQLObj tableObj, List<ChartFieldCustomFilterDTO> requestList) {
//        if (CollectionUtils.isEmpty(requestList)) {
//            return null;
//        }
//        List<String> res = new ArrayList<>();
//
//        for (ChartFieldCustomFilterDTO request : requestList) {
//            List<SQLObj> list = new ArrayList<>();
//            DatasetTableField field = request.getField();
//
//            if (ObjectUtils.isEmpty(field)) {
//                continue;
//            }
//            String whereName = "";
//            String originName;
//            if (ObjectUtils.isNotEmpty(field.getExtField()) && field.getExtField() == 2) {
//                // 解析origin name中有关联的字段生成sql表达式
//                originName = calcFieldRegex(field.getOriginName(), tableObj);
//            } else if (ObjectUtils.isNotEmpty(field.getExtField()) && field.getExtField() == 1) {
//                originName = String.format(MysqlConstants.KEYWORD_FIX, tableObj.getTableAlias(), field.getDataeaseName());
//            } else {
//                originName = String.format(MysqlConstants.KEYWORD_FIX, tableObj.getTableAlias(), field.getDataeaseName());
//            }
//
//            if (field.getDeType() == 1) {
//                if (field.getDeExtractType() == 0 || field.getDeExtractType() == 5 || field.getDeExtractType() == 1) {
//                    whereName = String.format(MysqlConstants.STR_TO_DATE, originName, MysqlConstants.DEFAULT_DATE_FORMAT);
//                }
//                if (field.getDeExtractType() == 2 || field.getDeExtractType() == 3 || field.getDeExtractType() == 4) {
//                    String cast = String.format(MysqlConstants.CAST, originName, MysqlConstants.DEFAULT_INT_FORMAT) + "/1000";
//                    whereName = String.format(MysqlConstants.FROM_UNIXTIME, cast, MysqlConstants.DEFAULT_DATE_FORMAT);
//                }
//            } else if (field.getDeType() == 2 || field.getDeType() == 3) {
//                if (field.getDeExtractType() == 0 || field.getDeExtractType() == 5) {
//                    whereName = String.format(MysqlConstants.CAST, originName, MysqlConstants.DEFAULT_FLOAT_FORMAT);
//                }
//                if (field.getDeExtractType() == 1) {
//                    whereName = String.format(MysqlConstants.UNIX_TIMESTAMP, originName) + "*1000";
//                }
//                if (field.getDeExtractType() == 2 || field.getDeExtractType() == 3 || field.getDeExtractType() == 4) {
//                    whereName = originName;
//                }
//            } else if (field.getDeType() == 0 && field.getDeExtractType() == 0) {
//                whereName = String.format(MysqlConstants.CAST, originName, MysqlConstants.CHAR);
//            } else {
//                whereName = originName;
//            }
//
//            if (StringUtils.equalsIgnoreCase(request.getFilterType(), "enum")) {
//                if (CollectionUtils.isNotEmpty(request.getEnumCheckField())) {
//                    res.add("(" + whereName + " IN ('" + String.join("','", request.getEnumCheckField()) + "'))");
//                }
//            } else {
//                List<ChartCustomFilterItemDTO> filter = request.getFilter();
//                for (ChartCustomFilterItemDTO filterItemDTO : filter) {
//                    String value = filterItemDTO.getValue();
//                    String whereTerm = transMysqlFilterTerm(filterItemDTO.getTerm());
//                    String whereValue = "";
//
//                    if (StringUtils.equalsIgnoreCase(filterItemDTO.getTerm(), "null")) {
//                        whereValue = "";
//                    } else if (StringUtils.equalsIgnoreCase(filterItemDTO.getTerm(), "not_null")) {
//                        whereValue = "";
//                    } else if (StringUtils.equalsIgnoreCase(filterItemDTO.getTerm(), "empty")) {
//                        whereValue = "''";
//                    } else if (StringUtils.equalsIgnoreCase(filterItemDTO.getTerm(), "not_empty")) {
//                        whereValue = "''";
//                    } else if (StringUtils.containsIgnoreCase(filterItemDTO.getTerm(), "in")) {
//                        whereValue = "('" + StringUtils.join(value, "','") + "')";
//                    } else if (StringUtils.containsIgnoreCase(filterItemDTO.getTerm(), "like")) {
//                        whereValue = "'%" + value + "%'";
//                    } else {
//                        // Doris field type test
//                        /*if (field.getDeExtractType() == 2 || field.getDeExtractType() == 3 || field.getDeExtractType() == 4) {
//                            whereValue = String.format(DorisConstants.WHERE_NUMBER_VALUE, value);
//                        } else {
//                            whereValue = String.format(DorisConstants.WHERE_VALUE_VALUE, value);
//                        }*/
//                        whereValue = String.format(MysqlConstants.WHERE_VALUE_VALUE, value);
//                    }
//                    list.add(SQLObj.builder()
//                            .whereField(whereName)
//                            .whereTermAndValue(whereTerm + whereValue)
//                            .build());
//                }
//
//                List<String> strList = new ArrayList<>();
//                list.forEach(ele -> strList.add(ele.getWhereField() + " " + ele.getWhereTermAndValue()));
//                if (CollectionUtils.isNotEmpty(list)) {
//                    res.add("(" + String.join(" " + getLogic(request.getLogic()) + " ", strList) + ")");
//                }
//            }
//        }
//        return CollectionUtils.isNotEmpty(res) ? "(" + String.join(" AND ", res) + ")" : null;
//    }

    private String reflectFieldName(DatasetTableField field) {
        return field.getDataeaseName();
    }

//    public String transExtFilterList(SQLObj tableObj, List<ChartExtFilterRequest> requestList) {
//        if (CollectionUtils.isEmpty(requestList)) {
//            return null;
//        }
//        List<SQLObj> list = new ArrayList<>();
//        for (ChartExtFilterRequest request : requestList) {
//            List<String> value = request.getValue();
//
//            List<String> whereNameList = new ArrayList<>();
//            List<DatasetTableField> fieldList = new ArrayList<>();
//            if (request.getIsTree()) {
//                fieldList.addAll(request.getDatasetTableFieldList());
//            } else {
//                fieldList.add(request.getDatasetTableField());
//            }
//
//            for (DatasetTableField field : fieldList) {
//                if (CollectionUtils.isEmpty(value) || ObjectUtils.isEmpty(field)) {
//                    continue;
//                }
//                String whereName = "";
//
//
//                String originName;
//                if (ObjectUtils.isNotEmpty(field.getExtField()) && field.getExtField() == 2) {
//                    // 解析origin name中有关联的字段生成sql表达式
//                    originName = calcFieldRegex(field.getOriginName(), tableObj);
//                } else if (ObjectUtils.isNotEmpty(field.getExtField()) && field.getExtField() == 1) {
//                    originName = String.format(MysqlConstants.KEYWORD_FIX, tableObj.getTableAlias(), field.getDataeaseName());
//                } else {
//                    originName = String.format(MysqlConstants.KEYWORD_FIX, tableObj.getTableAlias(), field.getDataeaseName());
//                }
//
//                if (field.getDeType() == 1) {
//                    if (field.getDeExtractType() == 0 || field.getDeExtractType() == 5 || field.getDeExtractType() == 1) {
//                        whereName = String.format(MysqlConstants.STR_TO_DATE, originName, MysqlConstants.DEFAULT_DATE_FORMAT);
//                    }
//                    if (field.getDeExtractType() == 2 || field.getDeExtractType() == 3 || field.getDeExtractType() == 4) {
//                        String cast = String.format(MysqlConstants.CAST, originName, MysqlConstants.DEFAULT_INT_FORMAT) + "/1000";
//                        whereName = String.format(MysqlConstants.FROM_UNIXTIME, cast, MysqlConstants.DEFAULT_DATE_FORMAT);
//                    }
//                } else if (field.getDeType() == 0 && field.getDeExtractType() == 0) {
//                    whereName = String.format(MysqlConstants.CAST, originName, MysqlConstants.CHAR);
//                } else if (field.getDeType() == 2 || field.getDeType() == 3) {
//                    if (field.getDeExtractType() == 0 || field.getDeExtractType() == 5) {
//                        whereName = String.format(MysqlConstants.CAST, originName, MysqlConstants.DEFAULT_FLOAT_FORMAT);
//                    }
//                    if (field.getDeExtractType() == 1) {
//                        whereName = String.format(MysqlConstants.UNIX_TIMESTAMP, originName) + "*1000";
//                    }
//                    if (field.getDeExtractType() == 2 || field.getDeExtractType() == 3 || field.getDeExtractType() == 4) {
//                        whereName = originName;
//                    }
//                } else {
//                    whereName = originName;
//                }
//                whereNameList.add(whereName);
//            }
//
//            String whereName = "";
//            if (request.getIsTree()) {
//                whereName = "CONCAT(" + StringUtils.join(whereNameList, ",',',") + ")";
//            } else {
//                whereName = whereNameList.get(0);
//            }
//            String whereTerm = transMysqlFilterTerm(request.getOperator());
//            String whereValue = "";
//
//            if (StringUtils.containsIgnoreCase(request.getOperator(), "in")) {
//                whereValue = "('" + StringUtils.join(value, "','") + "')";
//            } else if (StringUtils.containsIgnoreCase(request.getOperator(), "like")) {
//                whereValue = "'%" + value.get(0) + "%'";
//            } else if (StringUtils.containsIgnoreCase(request.getOperator(), "between")) {
//                if (request.getDatasetTableField().getDeType() == 1) {
//                    SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
//                    String startTime = simpleDateFormat.format(new Date(Long.parseLong(value.get(0))));
//                    String endTime = simpleDateFormat.format(new Date(Long.parseLong(value.get(1))));
//                    whereValue = String.format(MysqlConstants.WHERE_BETWEEN, startTime, endTime);
//                } else {
//                    whereValue = String.format(MysqlConstants.WHERE_BETWEEN, value.get(0), value.get(1));
//                }
//            } else {
//                // doris field type test
//                /*if (field.getDeExtractType() == 2 || field.getDeExtractType() == 3 || field.getDeExtractType() == 4) {
//                    whereValue = String.format(DorisConstants.WHERE_NUMBER_VALUE, value.get(0));
//                } else {
//                    whereValue = String.format(DorisConstants.WHERE_VALUE_VALUE, value.get(0));
//                }*/
//                whereValue = String.format(MysqlConstants.WHERE_VALUE_VALUE, value.get(0));
//            }
//            list.add(SQLObj.builder()
//                    .whereField(whereName)
//                    .whereTermAndValue(whereTerm + whereValue)
//                    .build());
//        }
//        List<String> strList = new ArrayList<>();
//        list.forEach(ele -> strList.add(ele.getWhereField() + " " + ele.getWhereTermAndValue()));
//        return CollectionUtils.isNotEmpty(list) ? "(" + String.join(" AND ", strList) + ")" : null;
//    }

    private String transDateFormat(String dateStyle, String datePattern) {
        String split = "-";
        if (StringUtils.equalsIgnoreCase(datePattern, "date_sub")) {
            split = "-";
        } else if (StringUtils.equalsIgnoreCase(datePattern, "date_split")) {
            split = "/";
        } else {
            split = "-";
        }

        if (StringUtils.isEmpty(dateStyle)) {
            return "%Y-%m-%d %H:%i:%S";
        }

        switch (dateStyle) {
            case "y":
                return "%Y";
            case "y_M":
                return "%Y" + split + "%m";
            case "y_M_d":
                return "%Y" + split + "%m" + split + "%d";
            case "H_m_s":
                return "%H:%i:%S";
            case "y_M_d_H_m":
                return "%Y" + split + "%m" + split + "%d" + " %H:%i";
            case "y_M_d_H_m_s":
                return "%Y" + split + "%m" + split + "%d" + " %H:%i:%S";
            default:
                return "%Y-%m-%d %H:%i:%S";
        }
    }

//    private SQLObj getXFields(ChartViewFieldDTO x, String originField, String fieldAlias) {
//        String fieldName = "";
//        if (x.getDeExtractType() == 1) {
//            if (x.getDeType() == 2 || x.getDeType() == 3) {
//                fieldName = String.format(MysqlConstants.UNIX_TIMESTAMP, originField) + "*1000";
//            } else if (x.getDeType() == 1) {
//                String format = transDateFormat(x.getDateStyle(), x.getDatePattern());
//                fieldName = String.format(MysqlConstants.DATE_FORMAT, originField, format);
//            } else {
//                fieldName = originField;
//            }
//        } else {
//            if (x.getDeType() == 1) {
//                String format = transDateFormat(x.getDateStyle(), x.getDatePattern());
//                if (x.getDeExtractType() == 0) {
//                    fieldName = String.format(MysqlConstants.DATE_FORMAT, originField, format);
//                } else {
//                    String cast = String.format(MysqlConstants.CAST, originField, MysqlConstants.DEFAULT_INT_FORMAT) + "/1000";
//                    String from_unixtime = String.format(MysqlConstants.FROM_UNIXTIME, cast, MysqlConstants.DEFAULT_DATE_FORMAT);
//                    fieldName = String.format(MysqlConstants.DATE_FORMAT, from_unixtime, format);
//                }
//            } else if (x.getDeType() == 0 && x.getDeExtractType() == 0) {
//                fieldName = String.format(MysqlConstants.CAST, originField, MysqlConstants.CHAR);
//            } else {
//                fieldName = originField;
//            }
//        }
//        return SQLObj.builder()
//                .fieldName(fieldName)
//                .fieldAlias(fieldAlias)
//                .build();
//    }
//
//    private List<SQLObj> getXWheres(ChartViewFieldDTO x, String originField, String fieldAlias) {
//        List<SQLObj> list = new ArrayList<>();
//        if (CollectionUtils.isNotEmpty(x.getFilter()) && x.getFilter().size() > 0) {
//            x.getFilter().forEach(f -> {
//                String whereName = "";
//                String whereTerm = transMysqlFilterTerm(f.getTerm());
//                String whereValue = "";
//                if (x.getDeType() == 1 && x.getDeExtractType() != 1) {
//                    String cast = String.format(MysqlConstants.CAST, originField, MysqlConstants.DEFAULT_INT_FORMAT) + "/1000";
//                    whereName = String.format(MysqlConstants.FROM_UNIXTIME, cast, MysqlConstants.DEFAULT_DATE_FORMAT);
//                } else {
//                    whereName = originField;
//                }
//                if (StringUtils.equalsIgnoreCase(f.getTerm(), "null")) {
//                    whereValue = "";
//                } else if (StringUtils.equalsIgnoreCase(f.getTerm(), "not_null")) {
//                    whereValue = "";
//                } else if (StringUtils.equalsIgnoreCase(f.getTerm(), "empty")) {
//                    whereValue = "''";
//                } else if (StringUtils.equalsIgnoreCase(f.getTerm(), "not_empty")) {
//                    whereValue = "''";
//                } else if (StringUtils.containsIgnoreCase(f.getTerm(), "in")) {
//                    whereValue = "('" + StringUtils.join(f.getValue(), "','") + "')";
//                } else if (StringUtils.containsIgnoreCase(f.getTerm(), "like")) {
//                    whereValue = "'%" + f.getValue() + "%'";
//                } else {
//                    whereValue = String.format(MysqlConstants.WHERE_VALUE_VALUE, f.getValue());
//                }
//                list.add(SQLObj.builder()
//                        .whereField(whereName)
//                        .whereAlias(fieldAlias)
//                        .whereTermAndValue(whereTerm + whereValue)
//                        .build());
//            });
//        }
//        return list;
//    }
//
//    private SQLObj getYFields(ChartViewFieldDTO y, String originField, String fieldAlias) {
//        String fieldName = "";
//        if (StringUtils.equalsIgnoreCase(y.getDataeaseName(), "*")) {
//            fieldName = MysqlConstants.AGG_COUNT;
//        } else if (SQLConstants.DIMENSION_TYPE.contains(y.getDeType())) {
//            if (StringUtils.equalsIgnoreCase(y.getSummary(), "count_distinct")) {
//                fieldName = String.format(MysqlConstants.AGG_FIELD, "COUNT", "DISTINCT " + originField);
//            } else {
//                fieldName = String.format(MysqlConstants.AGG_FIELD, y.getSummary(), originField);
//            }
//        } else {
//            if (StringUtils.equalsIgnoreCase(y.getSummary(), "avg") || StringUtils.containsIgnoreCase(y.getSummary(), "pop")) {
//                String cast = String.format(MysqlConstants.CAST, originField, y.getDeType() == 2 ? MysqlConstants.DEFAULT_INT_FORMAT : MysqlConstants.DEFAULT_FLOAT_FORMAT);
//                String agg = String.format(MysqlConstants.AGG_FIELD, y.getSummary(), cast);
//                String cast1 = String.format(MysqlConstants.CAST, agg, MysqlConstants.DEFAULT_FLOAT_FORMAT);
//                fieldName = String.format(MysqlConstants.ROUND, cast1, "2");
//            } else {
//                String cast = String.format(MysqlConstants.CAST, originField, y.getDeType() == 2 ? MysqlConstants.DEFAULT_INT_FORMAT : MysqlConstants.DEFAULT_FLOAT_FORMAT);
//                if (StringUtils.equalsIgnoreCase(y.getSummary(), "count_distinct")) {
//                    fieldName = String.format(MysqlConstants.AGG_FIELD, "COUNT", "DISTINCT " + cast);
//                } else {
//                    fieldName = String.format(MysqlConstants.AGG_FIELD, y.getSummary(), cast);
//                }
//            }
//        }
//        return SQLObj.builder()
//                .fieldName(fieldName)
//                .fieldAlias(fieldAlias)
//                .build();
//    }
//
//    private String getYWheres(ChartViewFieldDTO y, String originField, String fieldAlias) {
//        List<SQLObj> list = new ArrayList<>();
//        if (CollectionUtils.isNotEmpty(y.getFilter()) && y.getFilter().size() > 0) {
//            y.getFilter().forEach(f -> {
//                String whereTerm = transMysqlFilterTerm(f.getTerm());
//                String whereValue = "";
//                // 原始类型不是时间，在de中被转成时间的字段做处理
//                if (StringUtils.equalsIgnoreCase(f.getTerm(), "null")) {
//                    whereValue = "";
//                } else if (StringUtils.equalsIgnoreCase(f.getTerm(), "not_null")) {
//                    whereValue = "";
//                } else if (StringUtils.equalsIgnoreCase(f.getTerm(), "empty")) {
//                    whereValue = "''";
//                } else if (StringUtils.equalsIgnoreCase(f.getTerm(), "not_empty")) {
//                    whereValue = "''";
//                } else if (StringUtils.containsIgnoreCase(f.getTerm(), "in")) {
//                    whereValue = "('" + StringUtils.join(f.getValue(), "','") + "')";
//                } else if (StringUtils.containsIgnoreCase(f.getTerm(), "like")) {
//                    whereValue = "'%" + f.getValue() + "%'";
//                } else {
//                    whereValue = String.format(MysqlConstants.WHERE_VALUE_VALUE, f.getValue());
//                }
//                list.add(SQLObj.builder()
//                        .whereField(fieldAlias)
//                        .whereAlias(fieldAlias)
//                        .whereTermAndValue(whereTerm + whereValue)
//                        .build());
//            });
//        }
//        List<String> strList = new ArrayList<>();
//        list.forEach(ele -> strList.add(ele.getWhereField() + " " + ele.getWhereTermAndValue()));
//        return CollectionUtils.isNotEmpty(list) ? "(" + String.join(" " + getLogic(y.getLogic()) + " ", strList) + ")" : null;
//    }

//    private String calcFieldRegex(String originField, SQLObj tableObj) {
//        originField = originField.replaceAll("[\\t\\n\\r]]", "");
//        // 正则提取[xxx]
//        String regex = "\\[(.*?)]";
//        Pattern pattern = Pattern.compile(regex);
//        Matcher matcher = pattern.matcher(originField);
//        Set<String> ids = new HashSet<>();
//        while (matcher.find()) {
//            String id = matcher.group(1);
//            ids.add(id);
//        }
//        if (CollectionUtils.isEmpty(ids)) {
//            return originField;
//        }
//        DatasetTableFieldExample datasetTableFieldExample = new DatasetTableFieldExample();
//        datasetTableFieldExample.createCriteria().andIdIn(new ArrayList<>(ids));
//        List<DatasetTableField> calcFields = datasetTableFieldMapper.selectByExample(datasetTableFieldExample);
//        for (DatasetTableField ele : calcFields) {
//            originField = originField.replaceAll("\\[" + ele.getId() + "]",
//                    String.format(MysqlConstants.KEYWORD_FIX, tableObj.getTableAlias(), ele.getDataeaseName()));
//        }
//        return originField;
//    }
//
//    private String sqlLimit(String sql, ChartViewWithBLOBs view) {
//        if (StringUtils.equalsIgnoreCase(view.getResultMode(), "custom")) {
//            return sql + " LIMIT 0," + view.getResultCount();
//        } else {
//            return sql;
//        }
//    }
}
